class __temp__:
    def run(self,**kwargs):
        mqtt_obj=kwargs.get("mqtt_obj")
        send_topic=kwargs.get("send_topic")
        info=kwargs.get("info")
        #第一次运行 需要向mqtt服务注册
        if self.topic_flag is False:
            res=self.send_message(self,port=self.mqtt_obj,v255_flag=10,message_dct={"topic":self.match_topic})
        self.topic_flag=True